package org.aeon.gamechatnest.service;

import org.aeon.gamechatnest.common.response.Result;
import org.aeon.gamechatnest.pojo.ChatMessage;
import org.aeon.gamechatnest.socket.ChatMessageClient;

import java.util.List;
import java.util.concurrent.ConcurrentHashMap;

/**
 * @author : Qik 2024/5/15 11:34
 */
public interface ChannelChatMessageService {
    /**
     * 同步消息
     *
     * @param userId
     * @return
     */
    Result syncMessage(Long userId);

    /**
     * 消息处理
     *
     * @param webSocketMap
     * @param chatMessage
     */
    void handleMessage(ConcurrentHashMap<Long, ChatMessageClient> webSocketMap, ChatMessage chatMessage);
}
